// 版权所有2009 Go作者。保留所有权利。
// 此源代码的使用受BSD样式
// 许可证的约束，该许可证可以在许可证文件中找到。

// Package expvar为公共变量提供了一个标准化的接口，例如
// 作为服务器中的操作计数器。它通过HTTP在
// /debug/vars上以JSON格式公开这些变量。
// 
// 设置或修改这些公共变量的操作是原子操作。
// 
// 除了添加HTTP处理程序外，此包还注册了
// 以下变量：
// 
// cmdline os。Args 
// memstats运行时。Memstats 
// 
// 有时导入该包只是因为
// 注册其HTTP处理程序和上述变量的副作用。要使用它，请将此包链接到您的程序中：
// import“expvar”
// 
package expvar

import (
	"encoding/json"
	"fmt"
	"log"
	"math"
	"net/http"
	"os"
	"runtime"
	"sort"
	"strconv"
	"strings"
	"sync"
	"sync/atomic"
)

// Var是所有导出变量的抽象类型。
type Var interface {
	// String为变量返回一个有效的JSON值。
	// String方法不返回有效JSON的类型
	// （例如time.time）不能用作变量。
	String() string
}

// Int是满足Var接口的64位整数变量。
type Int struct {
	i int64
}

func (v *Int) Value() int64 {
	return atomic.LoadInt64(&v.i)
}

func (v *Int) String() string {
	return strconv.FormatInt(atomic.LoadInt64(&v.i), 10)
}

func (v *Int) Add(delta int64) {
	atomic.AddInt64(&v.i, delta)
}

func (v *Int) Set(value int64) {
	atomic.StoreInt64(&v.i, value)
}

// Float是一个满足Var接口的64位浮点变量。
type Float struct {
	f uint64
}

func (v *Float) Value() float64 {
	return math.Float64frombits(atomic.LoadUint64(&v.f))
}

func (v *Float) String() string {
	return strconv.FormatFloat(
		math.Float64frombits(atomic.LoadUint64(&v.f)), 'g', -1, 64)
}

// 添加将增量添加到v。
func (v *Float) Add(delta float64) {
	for {
		cur := atomic.LoadUint64(&v.f)
		curVal := math.Float64frombits(cur)
		nxtVal := curVal + delta
		nxt := math.Float64bits(nxtVal)
		if atomic.CompareAndSwapUint64(&v.f, cur, nxt) {
			return
		}
	}
}

// 将v设置为值。
func (v *Float) Set(value float64) {
	atomic.StoreUint64(&v.f, math.Float64bits(value))
}

// Map是满足Var接口的字符串到Var映射变量。
type Map struct {
	m      sync.Map // map[string]Var 
	keysMu sync.RWMutex
	keys   []string // 排序的
}

// KeyValue表示映射中的单个条目。
type KeyValue struct {
	Key   string
	Value Var
}

func (v *Map) String() string {
	var b strings.Builder
	fmt.Fprintf(&b, "{")
	first := true
	v.Do(func(kv KeyValue) {
		if !first {
			fmt.Fprintf(&b, ", ")
		}
		fmt.Fprintf(&b, "%q: %v", kv.Key, kv.Value)
		first = false
	})
	fmt.Fprintf(&b, "}")
	return b.String()
}

// Init从映射中删除所有密钥。
func (v *Map) Init() *Map {
	v.keysMu.Lock()
	defer v.keysMu.Unlock()
	v.keys = v.keys[:0]
	v.m.Range(func(k, _ any) bool {
		v.m.Delete(k)
		return true
	})
	return v
}

// addKey更新v.keys中已排序的键列表。
func (v *Map) addKey(key string) {
	v.keysMu.Lock()
	defer v.keysMu.Unlock()
	// 使用插入排序将密钥放入已排序的v.keys中。
	if i := sort.SearchStrings(v.keys, key); i >= len(v.keys) {
		v.keys = append(v.keys, key)
	} else if v.keys[i] != key {
		v.keys = append(v.keys, "")
		copy(v.keys[i+1:], v.keys[i:])
		v.keys[i] = key
	}
}

func (v *Map) Get(key string) Var {
	i, _ := v.m.Load(key)
	av, _ := i.(Var)
	return av
}

func (v *Map) Set(key string, av Var) {
	// 在存储值之前，请检查密钥是否是新的。在LoadOrStore之前尝试加载
	// LoadOrStore导致密钥接口转义，即使在加载路径上也是如此。
	if _, ok := v.m.Load(key); !ok {
		if _, dup := v.m.LoadOrStore(key, av); !dup {
			v.addKey(key)
			return
		}
	}

	v.m.Store(key, av)
}

// Add将delta添加到给定映射键下存储的*Int值中。
func (v *Map) Add(key string, delta int64) {
	i, ok := v.m.Load(key)
	if !ok {
		var dup bool
		i, dup = v.m.LoadOrStore(key, new(Int))
		if !dup {
			v.addKey(key)
		}
	}

	// 添加到Int；否则请忽略。
	if iv, ok := i.(*Int); ok {
		iv.Add(delta)
	}
}

// AddFloat将delta添加到给定映射键下存储的*Float值中。
func (v *Map) AddFloat(key string, delta float64) {
	i, ok := v.m.Load(key)
	if !ok {
		var dup bool
		i, dup = v.m.LoadOrStore(key, new(Float))
		if !dup {
			v.addKey(key)
		}
	}

	// 添加到浮点数；否则请忽略。
	if iv, ok := i.(*Float); ok {
		iv.Add(delta)
	}
}

// Delete从映射中删除给定的密钥。
func (v *Map) Delete(key string) {
	v.keysMu.Lock()
	defer v.keysMu.Unlock()
	i := sort.SearchStrings(v.keys, key)
	if i < len(v.keys) && key == v.keys[i] {
		v.keys = append(v.keys[:i], v.keys[i+1:]...)
		v.m.Delete(key)
	}
}

// Do为映射中的每个条目调用f。
// 在迭代过程中地图被锁定，
// 但现有条目可能会同时更新。
func (v *Map) Do(f func(KeyValue)) {
	v.keysMu.RLock()
	defer v.keysMu.RUnlock()
	for _, k := range v.keys {
		i, _ := v.m.Load(k)
		f(KeyValue{k, i.(Var)})
	}
}

// String是字符串变量，满足Var接口。
type String struct {
	s atomic.Value // 字符串
}

func (v *String) Value() string {
	p, _ := v.s.Load().(string)
	return p
}

// 字符串实现Var接口。要获取不带引号的字符串
// 请使用Value。
func (v *String) String() string {
	s := v.Value()
	b, _ := json.Marshal(s)
	return string(b)
}

func (v *String) Set(value string) {
	v.s.Store(value)
}

// Func通过调用函数
// 并使用JSON格式化返回值来实现Var。
type Func func() any

func (f Func) Value() any {
	return f()
}

func (f Func) String() string {
	v, _ := json.Marshal(f())
	return string(v)
}

// 所有已发布的变量。
var (
	vars      sync.Map // map[string]Var 
	varKeysMu sync.RWMutex
	varKeys   []string // 排序的
)

// Publish声明一个命名的导出变量。在创建变量时，应该从
// 包的init函数调用它。如果名称已经
// registered，则会记录。惊恐
func Publish(name string, v Var) {
	if _, dup := vars.LoadOrStore(name, v); dup {
		log.Panicln("Reuse of exported var name:", name)
	}
	varKeysMu.Lock()
	defer varKeysMu.Unlock()
	varKeys = append(varKeys, name)
	sort.Strings(varKeys)
}

// Get检索已命名的导出变量。如果名称
// 未注册，则返回nil。
func Get(name string) Var {
	i, _ := vars.Load(name)
	v, _ := i.(Var)
	return v
}

// 用于创建新导出变量的便利函数。

func NewInt(name string) *Int {
	v := new(Int)
	Publish(name, v)
	return v
}

func NewFloat(name string) *Float {
	v := new(Float)
	Publish(name, v)
	return v
}

func NewMap(name string) *Map {
	v := new(Map).Init()
	Publish(name, v)
	return v
}

func NewString(name string) *String {
	v := new(String)
	Publish(name, v)
	return v
}

// Do为每个导出的变量调用f。
// 全局变量映射在迭代期间被锁定，
// 但现有条目可能会同时更新。
func Do(f func(KeyValue)) {
	varKeysMu.RLock()
	defer varKeysMu.RUnlock()
	for _, k := range varKeys {
		val, _ := vars.Load(k)
		f(KeyValue{k, val.(Var)})
	}
}

func expvarHandler(w http.ResponseWriter, r *http.Request) {
	w.Header().Set("Content-Type", "application/json; charset=utf-8")
	fmt.Fprintf(w, "{\n")
	first := true
	Do(func(kv KeyValue) {
		if !first {
			fmt.Fprintf(w, ",\n")
		}
		first = false
		fmt.Fprintf(w, "%q: %s", kv.Key, kv.Value)
	})
	fmt.Fprintf(w, "\n}\n")
}

// 处理程序返回expvar HTTP处理程序。
// 
// 仅在非标准位置安装处理程序时才需要此选项。
func Handler() http.Handler {
	return http.HandlerFunc(expvarHandler)
}

func cmdline() any {
	return os.Args
}

func memstats() any {
	stats := new(runtime.MemStats)
	runtime.ReadMemStats(stats)
	return *stats
}

func init() {
	http.HandleFunc("/debug/vars", expvarHandler)
	Publish("cmdline", Func(cmdline))
	Publish("memstats", Func(memstats))
}
